package com.bzframework.example.kafka;

import org.apache.kafka.clients.admin.NewTopic;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.config.TopicBuilder;

/**
 * @Author bingzhong
 * @Date 2025/9/15
 */
@Configuration
public class KafkaConfiguration {

    @Bean
    public NewTopic newTopic() {

        return TopicBuilder
                .name("code-test-topic")
                .partitions(3)
                .replicas(3)
                .build();

    }


}
